type google.golang.org/grpc/internal/transport.http2Server

32 uses

	google.golang.org/grpc/internal/transport (current package)
		http2_server.go#L73: type http2Server struct {
		http2_server.go#L251: 	t := &http2Server{
		http2_server.go#L368: func (t *http2Server) operateHeaders(ctx context.Context, frame *http2.MetaHeadersFrame, handle func(*ServerStream)) error {
		http2_server.go#L670: func (t *http2Server) HandleStreams(ctx context.Context, handle func(*ServerStream)) {
		http2_server.go#L734: func (t *http2Server) getStream(f http2.Frame) (*ServerStream, bool) {
		http2_server.go#L752: func (t *http2Server) adjustWindow(s *ServerStream, n uint32) {
		http2_server.go#L762: func (t *http2Server) updateWindow(s *ServerStream, n uint32) {
		http2_server.go#L773: func (t *http2Server) updateFlowControl(n uint32) {
		http2_server.go#L795: func (t *http2Server) handleData(f *http2.DataFrame) {
		http2_server.go#L865: func (t *http2Server) handleRSTStream(f *http2.RSTStreamFrame) {
		http2_server.go#L880: func (t *http2Server) handleSettings(f *http2.SettingsFrame) {
		http2_server.go#L913: func (t *http2Server) handlePing(f *http2.PingFrame) {
		http2_server.go#L962: func (t *http2Server) handleWindowUpdate(f *http2.WindowUpdateFrame) {
		http2_server.go#L982: func (t *http2Server) checkForHeaderListSize(it any) bool {
		http2_server.go#L999: func (t *http2Server) streamContextErr(s *ServerStream) error {
		http2_server.go#L1009: func (t *http2Server) writeHeader(s *ServerStream, md metadata.MD) error {
		http2_server.go#L1038: func (t *http2Server) writeHeaderLocked(s *ServerStream) error {
		http2_server.go#L1078: func (t *http2Server) writeStatus(s *ServerStream, st *status.Status) error {
		http2_server.go#L1149: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
		http2_server.go#L1186: func (t *http2Server) keepalive() {
		http2_server.go#L1280: func (t *http2Server) Close(err error) {
		http2_server.go#L1306: func (t *http2Server) deleteStream(s *ServerStream, eosReceived bool) {
		http2_server.go#L1326: func (t *http2Server) finishStream(s *ServerStream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
		http2_server.go#L1350: func (t *http2Server) closeStream(s *ServerStream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
		http2_server.go#L1370: func (t *http2Server) Drain(debugData string) {
		http2_server.go#L1384: func (t *http2Server) outgoingGoAwayHandler(g *goAway) (bool, error) {
		http2_server.go#L1440: func (t *http2Server) socketMetrics() *channelz.EphemeralSocketMetrics {
		http2_server.go#L1447: func (t *http2Server) incrMsgSent() {
		http2_server.go#L1454: func (t *http2Server) incrMsgRecv() {
		http2_server.go#L1461: func (t *http2Server) getOutFlowWindow() int64 {
		http2_server.go#L1477: func (t *http2Server) Peer() *peer.Peer {
		logging.go#L30: func prefixLoggerForServerTransport(p *http2Server) *internalgrpclog.PrefixLogger {